//引入express模块
const express=require('express')
//引入与数据库相关的模块
const pool=require('../pool.js')
//创建路由器对象(固定语法)
const router=express.Router()
//往该路由器中添加多个子路由器
//用户登录
router.post('/login',(req,res,next)=>{
  var obj=req.body;
  pool.query('select*from xh_user where phone=?',[obj.phone],
  (err,data)=>{
    if(err){
      next(err);
      return;
    }
    //console.log(data);
    if(data.length==0){
      res.send({
        'code':0,
        'msg':'请输入正确的手机号'
      })
    }else{
      res.send({
        'code':1,
        'msg':'登录成功',
        'data':data
      })
    }
  })
})
//用户注册
router.post('/reg',(req,res,next)=>{
  var obj=req.body;
  pool.query('insert into userinfo set?;',[obj],(err,data)=>{
     if(err){
        next(err);
        return;
     }
     console.log(data)
        res.send({
           'code':1,
           'msg':'注册成功',
           'data':data 
     })
    
  })
})
//用户信息修改
router.put('/edit',(req,res,next)=>{
  //请求体参数
  let obj = req.body
  console.log(obj)
  //执行SQL命令
  //因为这个sql语句又长又数据多，因此写一个SQL变量验证没问题后在加到pool.query()里
  //u_names对应unames，u_phone对应uphnoe,u_member对应umember,约定一个没有更改的旧手机号oldphone
  let sql = `update userinfo set u_names="${obj.unames}",u_phone="${obj.uphone}",u_member=${obj.umember} where u_phone="${obj.oldphone}";`
  console.log(sql) 
  pool.query(sql,(err,data)=>{
    if(err){next(err);return}
    // data 是代表修改成功是该 data.affectedRows
    // console.log(data)
    if(data.affectedRows == 0){
      res.send({"code":0,"msg":"修改失败"})
    }else {
      res.send({"code":1,"msg":"修改成功"})
    }
  })
})


//导入路由器router
module.exports=router;